Review changes with  

Changed Files

File	Status
ethexe/node-loader/src/batch.rs	36% smaller
ethexe/node-loader/src/main.rs	1% smaller

Summary of Changes

Hello, I'm Gemini Code Assist¹! I'm currently reviewing this pull request and will post my feedback shortly. In the meantime, here's a summary to help you and other reviewers quickly get up to speed!

This pull request improves the robustness and observability of the node loader. By implementing per-batch timeouts, the system can now recover from stalled RPC operations. Additionally, the inclusion of SIGTERM support and periodic progress heartbeats ensures that the loader behaves more predictably in containerized environments and provides better operational feedback.

Highlights

• Batch Watchdog: Introduced a 180s timeout for each batch to prevent hung RPC calls from stalling the entire worker pool.
• Graceful Shutdown: Updated signal handling to listen for both SIGINT and SIGTERM, ensuring proper cleanup when using commands like 'docker stop'.
• Progress Monitoring: Added a 10s heartbeat log that reports completed, failed, and in-flight batch counts to improve visibility into pool status.

@claude fix review and also fix windows problems https://github.com/gear-tech/gear/actions/runs/25118845247/job/73613584380?pr=5393

Claude finished @grishasobol's task in 3m 5s —— View job

Fixed Windows CI Failure

• Read changed files
• Investigated Windows CI failure — tokio::signal::unix is unavailable on x86_64-pc-windows-msvc
• Fixed Windows compilation error (gated SIGTERM handling behind #[cfg(unix)])
• Addressed Gemini review feedback (see notes below)
• Committed and pushed

Fix applied (ethexe/node-loader/src/main.rs):

Wrapped the tokio::signal::unix import and sigterm listener in #[cfg(unix)], with a #[cfg(not(unix))] fallback that handles only SIGINT via ctrl_c():

async fn wait_for_shutdown_signal() -> std::io::Result<&'static str> {
    #[cfg(unix)]
    {
        use tokio::signal::unix::{SignalKind, signal};
        let mut sigterm = signal(SignalKind::terminate())?;
        tokio::select! {
            result = tokio::signal::ctrl_c() => result.map(|()| "Ctrl+C / SIGINT"),
            _ = sigterm.recv() => Ok("SIGTERM"),
        }
    }
    #[cfg(not(unix))]
    {
        tokio::signal::ctrl_c().await.map(|()| "Ctrl+C / SIGINT")
    }
}

Gemini review notes:

• Heartbeat initial tick (batch.rs:364): The heartbeat.tick().await is intentionally kept — it consumes the first immediate tick so the first heartbeat fires after HEARTBEAT_INTERVAL (10s), not at startup. MissedTickBehavior::Skip affects missed ticks, not the initial one. Removing it as Gemini suggested would cause a spurious heartbeat before any batch starts.
• ctrl_c() placement (main.rs:444): Already inline inside the select! branch (result = tokio::signal::ctrl_c()). Gemini's suggestion matches the existing code — no change needed.
  | Branch